package com.stream.consumer;


import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface ConsumeChannel {

    String inputChannel = "proConsumeChannel";

    String outChannel ="feedBackChannel";

    @Output(ConsumeChannel.outChannel)
    MessageChannel outChannel();

    @Input(ConsumeChannel.inputChannel)
    SubscribableChannel inputChannel();

}
